package net.wicp.tams.common.others.kafka;

public class KafkaConsumerThreadB extends KafkaConsumerThread<byte[]> {

	public KafkaConsumerThreadB(String groupId, String topic, IConsumer<byte[]> doConsumer) {
		super(groupId, topic, doConsumer);
	}

}
